#pragma once

//管理socket连接


#include "MessageQueueManager.h"
#include "ThirdPartyHeads.h"

class SocketManagerPair
{
public:
	SocketManagerPair();
	bool InitSockManager(std::string ip, uint16_t port, std::shared_ptr<MessageQueueManager> msgqueue);
	void StartSockManager();
	virtual ~SocketManagerPair();
	void RecvDataThreadFunc();
	void ProcDataThreadFunc();

public:
	std::shared_ptr<MessageQueueManager> _msgQueueP;

	std::string _listenIP;
	uint16_t	_listenPort;
	
};

